27df79bd2edeae135f534632f44ee32ffe65dfdc,mpush-netty/src/main/java/com/mpush/netty/server/NettyTCPServer.java,NettyTCPServer,createEpollServer,#Listener#,185
Before Change
private void createEpollServer(Listener listener) {
EpollEventLoopGroup bossGroup = new EpollEventLoopGroup(getBossThreadNum(), getBossThreadFactory());
EpollEventLoopGroup workerGroup = new EpollEventLoopGroup(getWorkThreadNum(), getWorkThreadFactory());
workerGroup.setIoRatio(getIoRate());
createServer(listener, bossGroup, workerGroup, EpollServerSocketChannel.class);
}
After Change
private void createEpollServer(Listener listener) {
EventLoopGroup bossGroup = getBossGroup();
EventLoopGroup workerGroup = getWorkerGroup();
if (bossGroup == null) {
EpollEventLoopGroup epollEventLoopGroup = new EpollEventLoopGroup(getBossThreadNum(), getBossThreadFactory());
epollEventLoopGroup.setIoRatio(100);
bossGroup = epollEventLoopGroup;
}
if (workerGroup == null) {
EpollEventLoopGroup epollEventLoopGroup = new EpollEventLoopGroup(getWorkThreadNum(), getWorkThreadFactory());
epollEventLoopGroup.setIoRatio(getIoRate());
workerGroup = epollEventLoopGroup;
}